package org.redis.cluster.test.transport.redis;

import org.junit.Assert;
import org.junit.Test;
import org.redis.cluster.redis.processor.RedisBulkReplyProcessor;
import org.redis.cluster.redis.transport.reply.RedisBulkReply;

public class RedisBulkReplyProcessorTester {

	@Test
	public void test() {
		RedisBulkReplyProcessor processor=new RedisBulkReplyProcessor();
		RedisBulkReply reply=new RedisBulkReply(1);
		byte result[]=processor.process(reply);
		Assert.assertEquals("$1\r\n1\r\n", new String(result));
	}
}